package com.juc.blockingQueue.LinkedTransferQueue.transfer2;

public class ThreadB1 extends Thread{

	private MyServiceB service;
	
	public ThreadB1(MyServiceB service) {
		super();
		this.service = service;
	}
	
	@Override
	public void run() {
		try {
			System.out.println(Thread.currentThread().getName() +"  begin  " + System.currentTimeMillis());
			System.out.println(" 取得的值： " + service.queue.take());
			System.out.println(Thread.currentThread().getName() +"  end  " + System.currentTimeMillis());

		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
